package com.bj.zspace.project.reactor.core;

import java.util.Arrays;
import java.util.List;

public class MyEventProcessor {

    private MyEventListener<String> listener;

    public void register(MyEventListener<String> listener) {
        this.listener = listener;
    }

    public void process() {
        listener.onDataChunk(Arrays.asList("a", "b", "c", "d"));
        listener.processComplete();
    }

    public List<String> history(long n) {
        List<String> list = Arrays.asList("a", "b", "c");
        return list;
    }

}
